package com.baor.demo;

import com.baor.handler.Server;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.io.IOException;

public class Main2 {
    public static void main(String[] args) throws IOException {
//        Flux.just("a", "b", "c").map(x -> x.toUpperCase()).subscribe(System.out::println);
//
//        Mono.just(new String("Hello")).map(x -> x.toUpperCase()).subscribe(System.out::println);


        Server server = new Server();
        server.createReactorServer();
        System.out.println("enter is exit");
        System.in.read();
    }
}
